基于 libpq 开发

libpq 是应用程序员使用 TDSQL-A PostgreSQL版 的 C 接口。libpq 是一个库函数的集合，它们允许客户端程序传递查询给TDSQL-A PostgreSQL版 后端服务器并且接收这些查询的结果。

libpq 也是很多其他 TDSQL-A PostgreSQL版 应用接口的底层引擎，包括为 C++、Perl、Python、Tcl 和 ECPG 编写的接口。

使用 libpq 的客户端程序必须包括头文件 libpq-fe.h，并必须与 libpq 库连接在一起。

示例代码

示例：进行数据库连接

1. 创建 conn_test.cpp 文件。

   #include <stdio.h>
   #include <stdlib.h>
   #include "libpq-fe.h"  
   int
   main(int argc, char **argv){
   const char *conninfo;
   PGconn   *conn;   
   if (argc > 1){
   conninfo = argv[1];
   }else{
   conninfo = "dbname = postgres"; 
   }      
   conn = PQconnectdb(conninfo);
   if (PQstatus(conn) != CONNECTION_OK){
   fprintf(stderr, "连接数据库失败: %s",PQerrorMessage(conn));       
   }else{
   printf("连接数据库成功！\n");
   }
   PQfinish(conn);
   return 0;
   }

2. 进行编译。

   gcc -c -I ~/user_1/tdata_02/tbase_v3_1/3.0.16/install/tbase_pgxz/include conn_test.cpp

3. 连接成可执行文件。

   gcc -o conn conn_test.o -L ~/user_1/tdata_02/tbase_v3_1/3.0.16/install/tbase_pgxz/lib/ -lpq

4. 进行数据库连接测试。

   ./conn "host=localhost dbname=postgres port=11345"

   连接数据库成功！

示例：创建表

1. 创建文件 createtable.c。

   #include <stdio.h>
   #include <stdlib.h>
   #include "libpq-fe.h"  
   int
   main(int argc, char **argv){
   const char *conninfo;
   PGconn   *conn;   
   PGresult  *res;
   const char *sql = "create table tdapg(id int,nickname text) ";
   if (argc > 1){
   conninfo = argv[1];
   }else{
   conninfo = "dbname = postgres";      
   }    
   conn = PQconnectdb(conninfo);
   if (PQstatus(conn) != CONNECTION_OK){
   fprintf(stderr, "连接数据库失败: %s",PQerrorMessage(conn));       
   }else{
   printf("连接数据库成功！\n");
   }
   res = PQexec(conn,sql);
   if(PQresultStatus(res) != PGRES_COMMAND_OK){
   fprintf(stderr, "建立数据表失败: %s",PQresultErrorMessage(res)); 
   }else{
   printf("建立数据表成功！\n");
   }
   PQclear(res);
   PQfinish(conn);
   return 0;
   }

2. 进行编译。

   gcc -c -I ~/user_1/tdata_02/tbase_v3_1/3.0.16/install/tbase_pgxz/include createtable .cpp

3. 连接成可执行文件。

   gcc -o createtable createtable.o -L ~/user_1/tdata_02/tbase_v3_1/3.0.16/install/tbase_pgxz/lib/ -lpq

4. 进行数据库连接测试。

   ./createtable "host=localhost dbname=postgres port=11345"

示例：数据插入

1. 创建文件 insert.c。

   #include <stdio.h>
   #include <stdlib.h>
   #include "libpq-fe.h"  
   int
   main(int argc, char **argv){
   const char *conninfo;
   PGconn   *conn;   
   PGresult  *res;
   const char *sql = "INSERT INTO tdapg (id,nickname) values(1,'tdapg'),(2,'pgxz')";
   if (argc > 1){
   conninfo = argv[1];
   }else{
   conninfo = "dbname = postgres";      
   }    
   conn = PQconnectdb(conninfo);
   if (PQstatus(conn) != CONNECTION_OK){
   fprintf(stderr, "连接数据库失败: %s",PQerrorMessage(conn));       
   }else{
   printf("连接数据库成功！\n");
   }
   res = PQexec(conn,sql);
   if(PQresultStatus(res) != PGRES_COMMAND_OK){
   fprintf(stderr, "插入数据失败: %s",PQresultErrorMessage(res)); 
   }else{
   printf("插入数据成功！\n");
   }
   PQclear(res);
   PQfinish(conn);
   return 0;
   }

2. 进行编译。

   gcc -c -I ~/user_1/tdata_02/tbase_v3_1/3.0.16/install/tbase_pgxz/include insert.cpp

3. 连接成可执行文件。

   gcc -o insert insert.o -L ~/user_1/tdata_02/tbase_v3_1/3.0.16/install/tbase_pgxz/lib/ -lpq

4. 进行数据库连接测试。

   ./insert "host=localhost dbname=postgres port=11345"

示例：进行数据查询

1. 创建文件 select.c。

   #include <stdlib.h>
   #include "libpq-fe.h"
   int
   main(int argc, char **argv){
   const char *conninfo;
   PGconn   *conn;
   PGresult  *res;
   const char *sql = "select * from tdapg";
   if (argc > 1){
   conninfo = argv[1];
   }else{
   conninfo = "dbname = postgres";
   }
   conn = PQconnectdb(conninfo);
   if (PQstatus(conn) != CONNECTION_OK){
   fprintf(stderr, "连接数据库失败: %s",PQerrorMessage(conn));
   }else{
   printf("连接数据库成功！\n");
   }
   res = PQexec(conn,sql);
   if(PQresultStatus(res) != PGRES_TUPLES_OK){
   fprintf(stderr, "插入数据失败: %s",PQresultErrorMessage(res));
   }else{
   printf("查询数据成功！\n");
   int rownum = PQntuples(res) ;
   int colnum = PQnfields(res);
   for(int j = 0;j< colnum; ++j){
     printf("%s\t",PQfname(res,j));
   }
   printf("\n");
   for(int i = 0;i< rownum; ++i){
     for(int j = 0;j< colnum; ++j){
       printf("%s\t",PQgetvalue(res,i,j));
     }
     printf("\n");
   }
   }
   PQclear(res);
   PQfinish(conn);
   return 0;
   }

2. 进行编译。

   gcc -std=c99 -c -I ~/user_1/tdata_02/tbase_v3_1/3.0.16/install/tbase_pgxz/include select.c

3. 连接成可执行文件。

   gcc -o select select.o -L ~/user_1/tdata_02/tbase_v3_1/3.0.16/install/tbase_pgxz/lib/ -lpq

4. 进行数据库连接测试。

   ./select"host=localhost dbname=postgres port=11345"